#include "../mqserver/mq_channel.hpp"
#include "muduo/net/Callbacks.h"
#include "muduo/proto/codec.h"
#include <memory>

/* 
  该模块无法进行单元测试, 因此只进行简单的编译测试
*/
int main()
{
    mqserver::ChannelManagerPtr channel_mp = std::make_shared<mqserver::ChannelManager>();
    channel_mp->openChannel(
        "channel[1]", 
        mqserver::ProtobufCodecPtr(), 
        muduo::net::TcpConnectionPtr(), 
        std::make_shared<mqserver::VirtualHost>("host1", "./data/host1/message/", "./data/host1/host1.db"), 
        std::make_shared<mqserver::ConsumerManager>(),
        pool::ThreadPoolPtr());
    
    return 0;
}